// pages/workerman/workerman.js
var myws
const app = getApp()

Page({

  /**
   * 页面的初始数据
   */
  data: {
    ctx:"",
    fromid:"1",//发送人id
    list:[{//接收消息的数值
      fromid:"1",
      toid:"2",
      data:"你好"
    },{
      fromid:"2",
      toid:"1",
      data:"你也好"
    },{
      fromid:"1",
      toid:"2",
      data:"hello hello"
    },]
  },

  //获取文本框内容
  ipt(res){
    this.setData({
      ctx:res.detail.value
    })
    // console.log(this.data.ctx)
  },

  //将文本框内容发送
  send(){
    // var obj = JSON.stringify({
    //   //转为json格式
    //   ctx:this.data.ctx
    // })

    var tmp = {
      data:this.data.ctx,
      fromid:this.data.fromid,
      toid:this.data.toid,
    }
    var obj = JSON.stringify(tmp)
    var list = this.data.list
    list.push(tmp)
    this.setData({
      list,
      content:""
    })

    wx.sendSocketMessage({
      data: this.data.ctx,
    })
  },

  /**
   * 生命周期函数--监听页面加载
   */
  onLoad(options) {

    var from_avatar
    var to_avatar

    //判断发送者id是否是1
    if(options.fromid == 1)
    {
      from_avatar = '/images/24.jpg'
      to_avatar = '/images/22.jpg'
    } else {
      from_avatar = '/images/22.jpg'
      to_avatar = '/images/24.jpg'
    }
    //将用户id和头像存入data，方便在前端展示
    this.setData({
      fromid:options.fromid,
      toid:options.toid,
      from_avatar,
      to_avatar
    })

    // wx.onSocketOpen((res) => {
    //   console.log(res)
    //   console.log('onSocketOpen')
    // })
    // wx.connectSocket({
    //   url: 'ws://127.0.0.1:8282',
    //   success:res=>{
    //     console.log(res)
    //     console.log('connectSuccess')
    //   }
    // })
    // wx.onSocketMessage((res) => {
    //   console.log(res)
    //   //解密json格式
    //   // var obj = JSON.parse(res.data)
    //   var obj = res.data
    //   console.log(obj)
    // })

      myws = wx.connectSocket({
        //创建一个WebSocket连接
        url: 'ws://127.0.0.1:8282',
        //所有https的网址都需要wss协议访问websocket
        // url: 'wss://43.143.104.188:8282',
        success:res=>{
          console.log(res)
          console.log('connectSuccess')
        }
      })
      app.globalData.myws = myws
      myws.onOpen((res) => {
        //监听WebSocket 连接打开的事件
        console.log(res)
        console.log('onSocketOpen')
        var obj = {
          fromid:this.data.fromid,
          type:'bind'
        }
      })
      myws.onMessage((res) => {
        //监听 WebSocket 接收到服务器的消息
        console.log(res)
        //解密json格式
        // var obj = JSON.parse(res.data)
        var obj = res.data
        console.log(obj)
        if(obj.fromid != this.data.fromid)
        {
          var list = this.data.list
          list.push(obj)
          this.setData({
            list
          })
        }
      })
  },

  /**
   * 生命周期函数--监听页面初次渲染完成
   */
  onReady() {

  },

  /**
   * 生命周期函数--监听页面显示
   */
  onShow() {

  },

  /**
   * 生命周期函数--监听页面隐藏
   */
  onHide() {

  },

  /**
   * 生命周期函数--监听页面卸载
   */
  onUnload() {

  },

  /**
   * 页面相关事件处理函数--监听用户下拉动作
   */
  onPullDownRefresh() {

  },

  /**
   * 页面上拉触底事件的处理函数
   */
  onReachBottom() {

  },

  /**
   * 用户点击右上角分享
   */
  onShareAppMessage() {

  }
})